MqttClient mqttClient;
设置主题回调(所有主题都走这个接口实现)
mqttClient.setCallback(new MqttAllTopicCallback());
public class MqttAllTopicCallback implements MqttCallback{
}
设置主题回调(规定什么主题走什么接口实现)
mqttClient.subscribe("sys/#", 1,new MqttRuleListner()); //规定sys/#主题走MqttRuleListner
public class MqttRuleListner implements IMqttMessageListener{
}
//注意这种方式不能走共享订阅，$queue和$share